package com.ehotting.mqbd.api;

public interface MQDBConstants {

    public final static String COLO = ":";

    public static final String  LINE = "-";

    public final static String DISPATCHER_HOST = "DISPATCHER";

    public final static String MONITOR_HOST = "MONITOR";

    public final static String REDIS_LOCK_KEY_RELOAD = "MQDB:LOCK:LOAD_SERVER_INFO";

    public final static String REDIS_LOCK_KEY_COUNT = "MQDB:LOCK:LOAD_SERVER_COUNT";

    public final static String REDIS_LOCK_KEY_MONITOR = "MQDB:LOCK:MONITOR";

    public final static String REDIS_LOCK_KEY_TCP_CHANNEL = "MQDB:LOCK:TCP_CHANNEL";

    public final static String SERVER_COUNT = "MQDB:SERVER_COUNT";

    public final static String SERVER_ALLOCATOR_LOCK = "MQDB:SERVER_ALLOCATOR:LOCK:";

    public final static String MODULE_INFO_KEY = "MQDB:MODULE_INFO:";

    public final static String SOLVER_INFO_KEY = "MQDB:SOLVER_INFO:";

    public final static String STORAGE = "MQDB:STORAGE:";

    public final static String CONSUMER_NODE = "MQDB:CONSUMER_NODE:";

    /**key:module+::+agentId**,value:ip+:+port**/
    public final static String AGENT_REF_SOLVER_IP = "MQDB:AGENT_REF_SOLVER_IP:";

    public final static String AGENT_REF_SOLVER_CHANNEL = "MQDB:AGENT_REF_SOLVER_CHANNEL:";

    public final static String AGENT_REF_CLIENT_IP = "MQDB:AGENT_REF_CLIENT_IP:";

    public final static String AGENT_REF_CONSUMER = "MQDB:AGENT_REF_CONSUMER:";

    public final static String QUEUE_MSG = "MQDB:QUEUE:MSG:";

    public final static  long TIME_OUT = 10;
}
